package com.euq.mq;

import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.euq.dto.OperationLogDto;

@Service
public class OperationLogProducer {

    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    public void sendOperationLog(String topic, OperationLogDto logDTO) {
        rocketMQTemplate.convertAndSend(topic, logDTO);
    }
}